# 1、安装依赖
# pip install pymysql

import pymysql

# 2、创建数据库链接
connect = pymysql.connect(host="master", port=3306, user="root", password="123456", database="bigdata")

# 3、获取游标，用于执行sql
cursor = connect.cursor()

# 4、执行sql查询数据
cursor.execute("select * from cars")

# 5、获取所有数据
# fetchall:一次将所有数据都读取到python的内存中，如果表的数据量大，会导致内存溢出
# students = cursor.fetchall()
#
# # 循环解析数据
# for id, name, age, sex, clazz in students:
#     print(f"{id}\t{name}\t{age}\t{sex}\t{clazz}")


# 一条一条读取
# fetchone：一次从数据库中拉取少量的数据
one = cursor.fetchone()
while one is not None:
    print(one)
    # 读取下一条
    one = cursor.fetchone()

# 6、关闭数据库链接
connect.close()
